import os
import django
# 设置 Django 环境
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'backend.settings')
django.setup()
from celery import current_app


# 清空所有任务队列
def clear_all_tasks():
    current_app.control.purge()

clear_all_tasks()